//package com.eks.websocket.v1;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.web.socket.WebSocketSession;
//
//import java.util.Objects;
//import java.util.concurrent.ConcurrentHashMap;
//
//@Slf4j
//public class WebSocketSessionManager {
//
//    private static final ConcurrentHashMap<String, WebSocketSession> SESSION_POOL = new ConcurrentHashMap<>();
//
//    public static void add(String key, WebSocketSession webSocketSession){
//        log.info("WebSocketSession.key: {}", key);
//        SESSION_POOL.put(key, webSocketSession);
//    }
//
//    public static WebSocketSession get(String key){
//        return SESSION_POOL.get(key);
//    }
//
//    public static WebSocketSession get(){
//        return SESSION_POOL.values().stream().findFirst().get();
//    }
//
//    public static WebSocketSession remove(String key){
//        return SESSION_POOL.remove(key);
//    }
//
//    public static void close(String key){
//        WebSocketSession webSocketSession = remove(key);
//        if(Objects.isNull(webSocketSession)){
//            return;
//        }
//        try{
//            webSocketSession.close();
//        }catch (Exception ignored){}
//    }
//}
